package com.ada.spark.action

import org.apache.spark.{SparkConf, SparkContext}

/**
  * 作用：返回一个由RDD的前n个元素组成的数组
  */
object Demo5_take {
    def main(args: Array[String]): Unit = {
        //创建SparkConf
        val conf = new SparkConf().setAppName("Demo5_take").setMaster("local[*]")
        //创建Spark上下文对象
        val sc = new SparkContext(conf)

        val rdd = sc.parallelize(1 to 10)

        //返回RDD中的第一个元素
        println(rdd.take(3).mkString(","))
        //1,2,3
    }
}
